package tom.spring.cloud.msg;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 输入管道，监听接收消息，消息消费者，管道返回类型必须为SubscribableChannel
 * @author ZHUFEIFEI
 */
public interface MyInput {
    String INPUT = "myInput";

    @Input(INPUT)
    SubscribableChannel input();
}